package com.agnes.network.observer;

import com.agnes.network.callback.RespCallback;

import io.reactivex.disposables.CompositeDisposable;
import okhttp3.ResponseBody;

/**
 * Desc:   返回ResponseBody
 * Creator ling
 * Date:   2017/12/18 0018 15:18
 */

public class BodyObserver extends BaseObserver<ResponseBody, ResponseBody> {

    public BodyObserver(RespCallback<ResponseBody> responseCallback,
        CompositeDisposable compositeDisposable) {
        super(responseCallback, compositeDisposable);
    }

    @Override
    public void onNext(ResponseBody responseBody) {
        mResponseCallback.onSuccess("", responseBody);
    }
}
